package com.yand.oratransmysql.service.impl;

import com.yand.oratransmysql.annotation.DataSource;
import com.yand.oratransmysql.config.DataSourceName;
import com.yand.oratransmysql.mapper.OracleTableInfoMapper;
import com.yand.oratransmysql.service.MysqlService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Map;


/**
 * mysql 业务类
 *
 *
 */
@Service
public class MysqlServiceImpl  implements MysqlService {

    @Autowired
    private OracleTableInfoMapper oracleTableInfoMapper;


    /**
     * 将抽取出来的数据 存放进mysql数据库中
     * @param param
     */
    @DataSource(DataSourceName.MYSQL)
    @Override
    public void insertTableData(Map<String, Object> param) {
        oracleTableInfoMapper.insertMySqlTableData(param);
    }
}
